package com.chaos.eurekaproducer.controller;

import com.chaos.eurekaproducer.EurekaProducerApplication;
import com.chaos.eurekaproducer.service.IUserService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;


/**
 * @author liaopeng
 * @title: JunitTestController
 * @projectName eureka-producer
 * @description: TODO
 * @date 2021/12/10上午9:57
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = EurekaProducerApplication.class)
public class JunitTestController {

    @Autowired
    private IUserService userService;
//
//    @Autowired
//    private KafkaProducer kafkaProducer;
//
//    @Autowired
//    private KafkaTemplate kafkaTemplate;

    @Test
    public void  send(){
//        List list = kafkaTemplate.partitionsFor("chaos.info");
//        kafkaProducer.send("chaos.info","kafka消息测试");
    }
}
